package com.kc.gb.device.plugins.ptl.service;

import com.kc.gb.device.plugins.ptl.events.support.PtlPublishEvent;
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.producer.DefaultMQProducer;


public interface PtlMQService {

    DefaultMQProducer getMqProducer();

    DefaultMQPushConsumer getMqConsumer();

    void sendFeedBackMessage(PtlPublishEvent command) throws Exception;

    DefaultMQProducer createCommandProducer() throws Exception;

    DefaultMQPushConsumer createCommandConsumer() throws Exception;
}
